package main

import (
	"iot-base/common/cache"
)

var SerialDataChanManager map[string]*PriorityQueue
var TcpDataChanManager map[string]*PriorityQueue

func init() {
	SerialDataChanManager = map[string]*PriorityQueue{}
	TcpDataChanManager = map[string]*PriorityQueue{}
}

func main() {
	//loader.SetParamEx(false, "serial", 10, task)
	serialF()
}

func task(id string, thing *cache.ThingInfo, v interface{}, round int64) (interface{}, error) {
	return nil, nil
}
